package com.kingsoft.dc.khaos.module

import com.kingsoft.dc.khaos.{DataSetChannel, KhaosContext, SchemaChannel}
import com.kingsoft.dc.khaos.metadata.Dependency
import org.apache.spark.rdd.RDD

/**
  * Created by chengguangqing on 2019/6/2.
  */
trait TSink {

  type MapSet = Map[String, String]

  def sink(_mid: String,
           dc: KhaosContext,
           config: String,
           dependence: Dependency,
           dataCollector: DataSetChannel,
           declarer: SchemaChannel): Any
}
